stream processing mechanism

流处理机制